ce5b82c88054bcfaf7b30d2e03392a2af2b6ed80,driver-core/src/test/java/com/datastax/driver/core/SpeculativeExecutionTest.java,SpeculativeExecutionTest,should_wait_until_all_executions_have_finished,#,158

Before Change


        scassandras.node(1).primingClient()
                // execution1 starts with host1, which will time out at t=1000
                .prime(PrimingRequest.queryBuilder()
                        .withQuery("mock query")
                        .withFixedDelay(2000)
                        .withRows(row("result", "result1"))
                        .build());
        // at t=1000, execution1 moves to host3, which eventually succeeds at t=1500
        scassandras.node(3).primingClient()

After Change


        scassandras.node(1).primingClient()
                // execution1 starts with host1, which will time out at t=1000
                .prime(PrimingRequest.queryBuilder()
                        .withQuery("mock query")
                        .withThen(then().withRows(row("result", "result1")).withFixedDelay(2000L))
                        .build());
        // at t=1000, execution1 moves to host3, which eventually succeeds at t=1500
        scassandras.node(3).primingClient()